/* Assume sufficient socket buffering for this message */
rc = syscall(SYS_write, sockfd, &hdr, sizeof(hdr));
if (rc <= 0) {
- CERROR ("Error %d sending HELLO to %llx\n", rc, *nid);
+ CERROR ("Error %d sending HELLO to "LPX64"\n", rc, *nid);
return (rc);
}
rc = syscall(SYS_read, sockfd, hmv, sizeof(*hmv));
if (rc <= 0) {
- CERROR ("Error %d reading HELLO from %llx\n", rc, *nid);
+ CERROR ("Error %d reading HELLO from "LPX64"\n", rc, *nid);
return (rc);
}
if (hmv->magic != __le32_to_cpu (PORTALS_PROTO_MAGIC)) {
- CERROR ("Bad magic %#08x (%#08x expected) from %llx\n",
+ CERROR ("Bad magic %#08x (%#08x expected) from "LPX64"\n",
__cpu_to_le32 (hmv->magic), PORTALS_PROTO_MAGIC, *nid);
return (-EPROTO);
}
if (hmv->version_major != __cpu_to_le16 (PORTALS_PROTO_VERSION_MAJOR) ||
hmv->version_minor != __cpu_to_le16 (PORTALS_PROTO_VERSION_MINOR)) {
CERROR ("Incompatible protocol version %d.%d (%d.%d expected)"
- " from %llx\n",
+ " from "LPX64"\n",
__le16_to_cpu (hmv->version_major),
__le16_to_cpu (hmv->version_minor),
PORTALS_PROTO_VERSION_MAJOR,
rc = syscall(SYS_read, sockfd, hmv + 1, sizeof(hdr) - sizeof(*hmv));
if (rc <= 0) {
- CERROR ("Error %d reading rest of HELLO hdr from %llx\n",
+ CERROR ("Error %d reading rest of HELLO hdr from "LPX64"\n",
rc, *nid);
return (rc);
}
if (hdr.type != __cpu_to_le32 (PTL_MSG_HELLO) ||
hdr.payload_length != __cpu_to_le32 (0)) {
CERROR ("Expecting a HELLO hdr with 0 payload,"
- " but got type %d with %d payload from %llx\n",
+ " but got type %d with %d payload from "LPX64"\n",
__le32_to_cpu (hdr.type),
__le32_to_cpu (hdr.payload_length), *nid);
return (-EPROTO);
if (*nid == PTL_NID_ANY) { /* don't know peer's nid yet */
*nid = __le64_to_cpu(hdr.src_nid);
} else if (*nid != __le64_to_cpu (hdr.src_nid)) {
- CERROR ("Connected to nid %llx, but expecting %llx\n",
+ CERROR ("Connected to nid "LPX64", but expecting "LPX64"\n",
__le64_to_cpu (hdr.src_nid), *nid);
return (-EPROTO);
}
*/
connection force_tcp_connection(manager m,
unsigned int ip,
- unsigned short port)
+ unsigned short port,
+ procbridge pb)
{
connection conn;
struct sockaddr_in addr;
exit(-1);
conn = allocate_connection(m, ip, port, fd);
+
+ /* let nal thread know this event right away */
+ if (conn)
+ procbridge_wakeup_nal(pb);
}
pthread_mutex_unlock(&m->conn_lock);