DCPVideoFrame dcp_video_frame (image, out_size, padding, scaler, frame, frames_per_second, post_process, colour_lut_index, j2k_bandwidth, &log_);
shared_ptr<EncodedData> encoded = dcp_video_frame.encode_locally ();
- encoded->send (fd);
+ encoded->send (socket);
#ifdef DEBUG_HASH
encoded->hash ("Encoded image (as made by server and as sent back)");
while (int (queue.size()) >= num_threads * 2) {
worker_condition.wait (lock);
}
-
- struct timeval tv;
- tv.tv_sec = 20;
- tv.tv_usec = 0;
- setsockopt (new_fd, SOL_SOCKET, SO_RCVTIMEO, (void *) &tv, sizeof (tv));
- setsockopt (new_fd, SOL_SOCKET, SO_SNDTIMEO, (void *) &tv, sizeof (tv));
queue.push_back (socket);
worker_condition.notify_all ();
}
- close (fd);
-
return 0;
}
def build(bld):
- for t in ['makedcp', 'fixlengths']:
+ for t in ['makedcp', 'fixlengths', 'servomatic']:
obj = bld(features = 'cxx cxxprogram')
obj.uselib = 'BOOST_THREAD'
obj.includes = ['..']